package com.fyy.kafuka.controller;

import com.fyy.kafuka.utils.MsgLafukaSendUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @Author fyy
 * @Description
 * @Date 2020/10/13 14:28
 */
@RestController
public class TestController {

    @Autowired
    MsgLafukaSendUtils msgkafak;

    @RequestMapping(value = "/send")
    public void sendKafkaMsg(String message){
        msgkafak.sendMsg(message);
    }

}
